package com.ql.consumer.service.impl;


import com.ql.consumer.exception.MessageException;

public interface IMessageProducer {
	public boolean publish(String topic, String message) throws MessageException;
}
